package cn.me.alphamq.broker.event.model.broker;

import cn.me.alphamq.common.entity.req.ConsumeMsgReq;
import cn.me.alphamq.common.event.model.Event;

/**
 * 消费消息的事件
 *
 * @author f
 */
public class ConsumeMsgEvent extends Event {

    /**
     * 消费消息的请求对象
     */
    private ConsumeMsgReq consumeMsgReq;

    public ConsumeMsgEvent(ConsumeMsgReq consumeMsgReq) {
        this.consumeMsgReq = consumeMsgReq;
    }

    public ConsumeMsgReq getConsumeMsgReq() {
        return consumeMsgReq;
    }

    public void setConsumeMsgReq(ConsumeMsgReq consumeMsgReq) {
        this.consumeMsgReq = consumeMsgReq;
    }
}
